from pymysql import Connection

conn = None

try:
    conn = Connection(host='linux.server', port=3306, user='root', password='Chenhao$123456', database='db_pymysql')
    # 创建游标对象
    cursor = conn.cursor()
    # 定义一个建表SQL语句
    sql = """
        create table if not exists `tb_user` (
            `id` int(11) not null auto_increment,
            `name` varchar(20) not null,
            `age` int(11) not null,
            `email` varchar(50) not null,
            primary key (`id`)
        ) engine=InnoDB default charset=utf8
    """

    # 选择要操作的数据库
    # 可以在创建连接时指定数据库
    # conn.select_db('db_pymysql')

    # 使用游标对象执行SQL
    cursor.execute(sql)

    # 关闭游标对象
    # 实际应用中，无需关闭。在关闭连接时，游标自动关闭了
    # 可省略
    cursor.close()

except Exception as e:
    print("error：", e)
finally:
    if conn:
        conn.close()
